d2948b2388ed091139810805a188cd105317b571,jrpc-transport-netty4/src/main/java/com/dinstone/jrpc/transport/netty4/TransportProtocolDecoder.java,TransportProtocolDecoder,readFrame,#ByteBuf#,71

Before Change


                    + ')');
        }

        if (remaining - 4 >= objectSize) {
            objectSize = in.readInt();
            // RPC object size
            byte[] rpcBytes = new byte[objectSize];
            in.readBytes(rpcBytes);

After Change


    private byte[] readFrame(ByteBuf in) {
        if (in.readableBytes() > 4) {
            in.markReaderIndex();
            int len = in.readInt();
            if (len > maxObjectSize) {
                throw new IllegalStateException("The encoded object is too big: " + len + " (> " + maxObjectSize + ")");
            } else if (len < 1) {